package com.hadoop.mr2.inputwordcount;

import java.io.IOException;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

/*
 * 现在输入key要变成每行行号，并且为IntWritable
 * 输出value每行内容
 */
public class WordCountMapper extends Mapper<IntWritable,Text,IntWritable,Text>{
	
	@Override
	protected void map(IntWritable key, Text value, Mapper<IntWritable, Text, IntWritable, Text>.Context context)
			throws IOException, InterruptedException {
		//做测试，看输入key和输入value的值
		context.write(key, value);
	}

}
